
/**
 * 所有的数据库的访问方法
 */
let pool = require('./init')
let query = function (sql, data = {}) {
    return new Promise((resolve, reject) => {
        pool.getConnection(function (err, conn) {
            if (err) {
                reject(new Error('数据库连接池连接失败'))
            } else {
                conn.query(sql, Object.values(data), function (qerr, vals, fields) {
                    //释放连接
                    conn.release();
                    //事件驱动回调
                    if (qerr) {
                        reject(new Error('sql语句执行发生错误'))
                    } else {
                        resolve(vals)
                    }
                });
            }
        });
    })
};

module.exports = query;